package edu.javeriana.aes.psw.forwarder;

import edu.javeriana.aes.psw.mensaje.Mensaje;
import edu.javeriana.aes.psw.util.NetworkUtil;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;

public class TCPForwarder implements Forwarder {

    @Override
    public void enviar(Mensaje mensaje) throws IOException {
        Socket socket = new Socket(mensaje.getIp(), 8899);
        DataOutputStream dos = new DataOutputStream(socket.getOutputStream());
        dos.writeBytes(NetworkUtil.obtenerIP());
        dos.writeBytes(mensaje.getAlias());
        dos.writeDouble(mensaje.getTemperatura());
        dos.writeLong(mensaje.getTimestamp());
        dos.writeInt(mensaje.getFrecuencia());
        dos.flush();
        socket.close();
    }
}
